package com.we.flink.userlabelplatform.table;

import java.sql.Timestamp;

public class TableTieCardAmountRecord {
    public static final String KFKTABLE = "fdm.hhl01_tie_card_amount_record";
    public static final String QUERYSQL =
            "select uid, increase_req_id, status, increase_time, "
                    + "if(expire_time is null, TIMESTAMP '1970-01-01 08:00:00.000000', expire_time) as expire_time, "
                    + " update_time from "
                    + KFKTABLE
                    + " where uid is not null "
                    + "and status is not null "
                    + "and increase_time is not null "
                    + "and update_time is not null "
                    + "and increase_req_id is not null";

    public long uid;
    public int status;
    public String increase_req_id;
    public Timestamp increase_time;
    public Timestamp expire_time;
    public Timestamp update_time;

    public TableTieCardAmountRecord() {}

    public TableTieCardAmountRecord(
            long uid,
            int status,
            String increase_req_id,
            Timestamp increase_time,
            Timestamp expire_time,
            Timestamp update_time) {
        this.uid = uid;
        this.status = status;
        this.increase_req_id = increase_req_id;
        this.increase_time = increase_time;
        this.expire_time = expire_time;
        this.update_time = update_time;
    }

    public String getIncrease_req_id() {
        return increase_req_id;
    }

    public int getStatus() {
        return status;
    }

    public long getUid() {
        return uid;
    }

    public Timestamp getExpire_time() {
        return expire_time;
    }

    public Timestamp getIncrease_time() {
        return increase_time;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }
}
